package org.dandsoft.blackbox.mapreduce.dispatcher;

import java.util.Map;

/**
 * @author Vilyuzhanin Denis (Fin)
 */
public interface ProcessCallbackHandler {

    Map handleInput(ProcessId pid, TaskDispatcher dispatcher, String inputName);

    void handleOutput(ProcessId pid, TaskDispatcher dispatcher, String outputName, Map map);

    void processStarted(ProcessId pid, TaskDispatcher dispatcher);

    void processStoped(ProcessId pid, TaskDispatcher dispatcher);

    void processError(ProcessId pid, TaskDispatcher dispatcher, Throwable t);
}
